package com.lmax.disruptor.demo;


public class Main {
    public static void main(String[] args){
        MallDisruptor<DisruptorTask> disruptor = new MallDisruptor<>(new TaskDisruptorConsumer());

        for(int i=0;i<100;i++){
            disruptor.getProvider().onData(() -> {
                System.out.println(Thread.currentThread().getName());
                System.out.println(1);
                System.out.println();
            });
        }
    }
}










































































































































































































































